6c2c533f67044e038cb8e1567b784c541c15692f,src/test/java/com/couchbase/client/java/CouchbaseAsyncBucketTest.java,CouchbaseAsyncBucketTest,shouldNotCallIntoObserveOnRemoveWhenNotNeeded,#,109
Before Change
core, null, "bucket", "", Collections.<Transcoder<? extends Document, ?>>emptyList()
);
when(core.send(any(RemoveRequest.class))).thenReturn(Observable.just((CouchbaseResponse) new RemoveResponse(
ResponseStatus.SUCCESS, KeyValueStatus.SUCCESS.code(), 1234, "bucket", Unpooled.EMPTY_BUFFER, null, mock(CouchbaseRequest.class)
)));
JsonDocument doc = JsonDocument.create("foo");
Observable<JsonDocument> result = bucket.remove(doc, PersistTo.NONE, ReplicateTo.NONE);
After Change
core, null, "bucket", "", Collections.<Transcoder<? extends Document, ?>>emptyList()
);
Subject<CouchbaseResponse, CouchbaseResponse> response = AsyncSubject.create();
response.onNext(new RemoveResponse(
ResponseStatus.SUCCESS, KeyValueStatus.SUCCESS.code(), 1234, "bucket", Unpooled.EMPTY_BUFFER, null, mock(CouchbaseRequest.class)
));
response.onCompleted();
when(core.send(any(RemoveRequest.class))).thenReturn(response);
JsonDocument doc = JsonDocument.create("foo");
Observable<JsonDocument> result = bucket.remove(doc, PersistTo.NONE, ReplicateTo.NONE);